//package com.culture.bootdemo.mq.rocketmq.customer;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.PostConstruct;
//import javax.annotation.Resource;
//
///**
// * @Author: wenjl
// * @Date: 2022/3/4 15:59
// * @Description:
// */
//@Slf4j
//@Component
//public class ComputeTaskMqConsumer {
//
//    @Value("${rocketmq.topic.order.status.topic:}")
//    private String orderStatusTopic;
//
//    /**
//     * 多个tag 用|| 分开
//     */
//    @Value("${rocketmq.topic.order_status_tags:}")
//    private String orderStatusTags;
//
//
//    @Resource(name = "computeTaskConsumer")
//    private SimpleConsumer computeTaskConsumer;
//
//
//    /**
//     *
//     */
//    @PostConstruct
//    public void computeTaskConsumer() {
//        log.info("---------------computeTaskConsumer --------------------");
//        try {
//            computeTaskConsumer.subscribe(orderStatusTopic, orderStatusTags, message -> {
//                return true;
//            });
//        } catch (Exception e) {
//            log.error("computeTaskConsumer Exception e ", e);
//        }
//
//
//    }
//
//}
